JDBC - Lưu Vĩnh Tường - 22133064
hive --service hiveserver2 &
netstat -tulnp | grep 10000
như hình là đã ổn
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveCreateDb {
private static String driverName = "org.apache.hive.jdbc.HiveDriver";
public static void main(String[] args) throws SQLException, ClassNotFoundException {
Class.forName(driverName);
Connection con = DriverManager.getConnection("jdbc:hive2://localhost:10000/default", "", "");
Statement stmt = con.createStatement();
stmt.executeUpdate("CREATE DATABASE IF NOT EXISTS userdb");
System.out.println("Database 'userdb' created successfully.");
stmt.close();
con.close();
}
}
javac -cp "$(find "${HIVE_HOME}/lib" -name '*.jar' | tr 'n' ':')" HiveCreateDb.java
java -cp "$(find "$HIVE_HOME/lib" -name '*.jar' | tr '\n' ':'):$(find "$HADOOP_HOME/share/hadoop/common/lib" -name '*.jar' | tr '\n' ':'):$(find "$HADOOP_HOME/share/hadoop/common" -name '*.jar' | tr '\n' ':'):./" HiveCreateDb
=> Kết quả trả về là tạo thành công => chương trình đã hoạt động
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveDropDB {
private static String driverName = "org.apache.hive.jdbc.HiveDriver";
public static void main(String[] args) throws SQLException, ClassNotFoundException {
Class.forName(driverName);
Connection con = DriverManager.getConnection("jdbc:hive2://localhost:10000/default", "", "");
Statement stmt = con.createStatement();
stmt.executeUpdate("DROP DATABASE userdb");
System.out.println("Drop userdb database successful.");
stmt.close();
con.close();
}
}
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveCreateTable {
private static String driverName = "org.apache.hive.jdbc.HiveDriver";
public static void main(String[] args) throws SQLException, ClassNotFoundException {
Class.forName(driverName);
Connection con = DriverManager.getConnection("jdbc:hive2://localhost:10000/userdb", "", "");
Statement stmt = con.createStatement();
stmt.executeUpdate("CREATE TABLE IF NOT EXISTS "
+ " employee (eid INT, name STRING, "
+ " salary STRING, destignation STRING) "
+ " COMMENT 'Employee details' "
+ " ROW FORMAT DELIMITED "
+ " FIELDS TERMINATED BY '\\t' "
+ " LINES TERMINATED BY '\\n' "
+ " STORED AS TEXTFILE");
System.out.println("Table employee created.");
con.close();
}
}
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveAlterTable {
private static String driverName = "org.apache.hive.jdbc.HiveDriver";
public static void main(String[] args) throws SQLException, ClassNotFoundException {
Class.forName(driverName);
Connection con = DriverManager.getConnection("jdbc:hive2://localhost:10000/userdb", "", "");
Statement stmt = con.createStatement();
stmt.executeUpdate("ALTER TABLE employee RENAME TO emp");
System.out.println("Table Renamed Successfully");
con.close();
}
}
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
public class HiveDropTable {
private static String driverName = "org.apache.hive.jdbc.HiveDriver";
public static void main(String[] args) throws SQLException, ClassNotFoundException {
Class.forName(driverName);
Connection con = DriverManager.getConnection("jdbc:hive2://localhost:10000/userdb", "", "");
Statement stmt = con.createStatement();
stmt.executeUpdate("DROP TABLE IF EXISTS employee");
System.out.println("Drop table successful.");
con.close();
}
}